package com.example.rocketmq.demo.config;

/**
 * RocketMQ 常量定义
 */
public class RocketMQConstant {
    // 普通消息主题
    public static final String TOPIC_NORMAL = "TOPIC_NORMAL";
    
    // 顺序消息主题
    public static final String TOPIC_ORDER = "TOPIC_ORDER";
    
    // 延时消息主题
    public static final String TOPIC_DELAY = "TOPIC_DELAY";
    
    // 批量消息主题
    public static final String TOPIC_BATCH = "TOPIC_BATCH";
    
    // 事务消息主题
    public static final String TOPIC_TRANSACTION = "TOPIC_TRANSACTION";
    
    // 过滤消息主题
    public static final String TOPIC_FILTER = "TOPIC_FILTER";
    
    // 消息标签
    public static final String TAG_NORMAL = "TAG_NORMAL";
    public static final String TAG_ORDER = "TAG_ORDER";
    public static final String TAG_DELAY = "TAG_DELAY";
    public static final String TAG_BATCH = "TAG_BATCH";
    public static final String TAG_TRANSACTION = "TAG_TRANSACTION";
    public static final String TAG_FILTER_A = "TAG_FILTER_A";
    public static final String TAG_FILTER_B = "TAG_FILTER_B";
    public static final String TAG_FILTER_C = "TAG_FILTER_C";
    
    // 消费者组
    public static final String CONSUMER_GROUP_NORMAL = "CONSUMER_GROUP_NORMAL";
    public static final String CONSUMER_GROUP_ORDER = "CONSUMER_GROUP_ORDER";
    public static final String CONSUMER_GROUP_DELAY = "CONSUMER_GROUP_DELAY";
    public static final String CONSUMER_GROUP_BATCH = "CONSUMER_GROUP_BATCH";
    public static final String CONSUMER_GROUP_TRANSACTION = "CONSUMER_GROUP_TRANSACTION";
    public static final String CONSUMER_GROUP_FILTER = "CONSUMER_GROUP_FILTER";
}